package org.wejob.nettytest;

import io.netty.channel.*;

import java.net.SocketAddress;

public class InboundHandlerTest extends SimpleChannelInboundHandler {

    @Override
    protected void channelRead0(ChannelHandlerContext ctx, Object msg) throws Exception {
        System.out.println("registered   "+Thread.currentThread().getName());
        System.out.println(msg.toString());
        System.out.println(ctx.pipeline().names());
        ctx.fireChannelRead(msg);
    }
}
